#ifndef __FACTORY_H__
#define __FACTORY_H__
#include "head.h"
#include "work_que.h"
//子线程对应结构体
typedef struct{
    que_t que;
    pthread_t *pthid;//指向线程id数组的指针
    pthread_cond_t cond;
    int threadnum;//线程总数目
    int startflag;//标记是否启动:0:start;1:end
}factory_t,*pfactory_t;
typedef struct{
    int dataLen;//存储发送的数据长度
    char buf[1024];
}train_t;//数据火车
int factory_init(factory_t*,int,int);
int factory_start(pfactory_t);
void *threadfunc(void*);
int tcp_init(int*,char*,char*);
int trans_file(int);
#endif
